package org.hbhk.test.schedule;

import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;

import org.hbhk.aili.job.annotation.JobConfig;

import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.dataflow.DataflowJob;
import com.google.common.collect.Lists;

@JobConfig(cron = "*/5 * * * * ?", name = "ScheduleTest2")
public class ScheduleTest2 implements DataflowJob<String> {

	public static final AtomicInteger counter = new AtomicInteger(0);

	@Override
	public List<String> fetchData(ShardingContext shardingContext) {
		return Lists.newArrayList("111");
	}

	@Override
	public void processData(ShardingContext shardingContext, List<String> data) {
//		System.out.println(2 / 0);
//
//		for (String string : data) {
//			System.out.println(string);
//		}

	}
}
